package com.example.artemis.config;

/**
 * 消费者配置实现类
 * 基于原有代码的消费者配置参数
 */
public class QueueConsumerConfig extends AbstractConsumerConfig {

    /**
     * 消费者数量 - 5个消费者
     */
    @Override
    public int getConsumerCount() {
        return 5;
    }

    /**
     * 队列名称数组 - 5个分片队列
     */
    @Override
    public String[] getQueueNames() {
        return new String[]{
            "demo.queue.0",
            "demo.queue.1",
            "demo.queue.2",
            "demo.queue.3",
            "demo.queue.4"
        };
    }

    /**
     * 最大重试次数 - 适配原有的重试逻辑
     */
    @Override
    public int getMaxRetryCount() {
        return 5;
    }

    /**
     * 重试延迟时间
     */
    @Override
    public long getRetryDelayMs() {
        return 500L; // 500毫秒
    }
}